package com.quarkus.db.service;


/**
 * @Author: TongRui乀
 * @Date: 2021/3/21 11:03
 * @description：
 */
//@ApplicationScoped
//public class DbReactiveOperationService {
//
//    @Inject
//    @ReactiveDataSource("re")
//    PgPool pgPool;
//
//
//    public Uni<String> getById(Integer id){
//
//        return pgPool.preparedQuery("select * from t_user where id = $1").execute(Tuple.of(id))
//        .onItem()
//        .transform(rows -> {
//            var res = rows.iterator().next();
//            var idd = res.getInteger("id");
//            var name = res.getString("name");
//            return idd + ", " + name;
//        }).onFailure()
//                .recoverWithItem(e->{
//                    e.printStackTrace();
//                    return "ERROR";
//                });
//    }
//
//}
